package com.example.demo.jucConcurrent.ThreadPoolExecutor详解;

import java.util.concurrent.*;

/**
 * ThreadPoolExecutor使用详解
 * 01其实java线程的实现原来很简单,说白了就是一个线程集合WorkerSet和一个阻塞队列workQueue,当用户向线程池
 * 提交了一个任务(也就是线程)时,
 * 02线程会先将任务放入WorQueue中,workSet中的线程会不断的从workQueue中获取到线程然后执行,当workQueue中没有任务队列的是
 * worker就会阻塞,直到队列中有任务的时候取出来就行了
 *
 * Executor原理:
 * 当一个任务提交线程之后
 * 01:线程池首先当前运行的线程数量是否小于corePoolSize,如果是则创建一个新的工作线程类执行任务,如果都在执行任务,则进入2
 * 02:判断BlockingQueue是否需已满了,倘若还没满,则把线程放入BlockingQueue,否则进入3
 * 03:如果创建一个新的工作线程将使用当前运行的线程数量超过maxPooolSize则交给RejectedExecutorHandler来处理任务.
 *
 *当ThreadPoolExecutor创建新线程时,通过CAS来更新线程时的状态
 */
public class WorkerPool {
    public static void main(String[] args) {



        //RejectedExecutionHandler implementation
        //Get the ThreadFactory implementation to use
        ThreadFactory threadFactory = Executors.defaultThreadFactory();

        ThreadPoolExecutor executorPool = new ThreadPoolExecutor(
                2,
                4,
                10L,
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(2),
                threadFactory,
                new ThreadPoolExecutor.AbortPolicy());

        /**
         * CorePoolSize:核心线程数
         *        线程池中的核心线程数,当提交一个任务时,线程池创建一个新线程执行任务,
         *        直到当前的线程数等于CorePoolSize,即使有其他空闲线程能够执行新来的任务,也会继续创建线程,
         *        如果当前线程数为CorePoolSize,继续提交的任务被保存到阻塞队列中,等待被执行,如果执行了线程池
         *        prestartAllCoreThread()方法,线程池会提前创建启动所有的核心线程池.
         *
         *
         * workQueue:
         *      用来保存等待被执行的任务的阻塞队列,在jdk中提供了如下的祖苏队列:具体如下:
         *      01:ArrayBlockingQueue:基于数组结构的有界阻塞队列,按FIFO排序任务
         *      02:LinkedBlockingQuene:基于链表结构的阻塞队列,按FIFO安排任务,吞吐量要高于ArrayBlocking;
         *      03:SynrononsQueue:一个不存储元素的阻塞队列,每个插入操作都必须等另一个线程调用移除操作,否则插入操作一直处于阻塞状态,吞吐量长高于LinkedBlockingQueue
         *      04:priorityBlockingQueue:具有优先级的无界阻塞队列
         *
         *      说明:LinkedBlockingQueue比ArrayBlockingQueue在插入删除节点性能方面更优,但是二者在put(),take(),任务的事均需要加锁,
         *      synchrononsQueue使用无锁算法,根据节点的状态判断执行,则不需要用到锁,其核心是Transfer.transfer().
         *
         * maxmumPoolSize 线程池中允许的UI大线程数,
         *          如果当前队列满了,且继续提交任务,则创建新 的线程执行任务,
         *      前提是当前线程小于maxmunPoolSize;当阻塞队列是无界队列,则maximumPoolSize则不起作用,因为无法提交至核心线程池的线程会一直持续放入WorkQueue
         *
         *      keepAliveTime:线程空闲时的存活时间,即当前线程没有任务执行时,该线程继续存活的时间,默认情况下,该参数只在线程数大于CorePoolSize时才有用,超过这个时候的空闲
         *      线程将被终止.
         *
         *      unit:keepAliveTime的单位
         *
         *      threadFactory: 创建线程的工厂,通过自定义的线程工厂可以给每个新建的线程设置一个具有识别度的线程
         *      名,默认为DefaultThreadFactory
         *
         *      Handler线程池的饱和策略:当阻塞队列满了,且没有空闲的工作线程,如果继续提交任务,必须采用一种策略处理该任务,线程池提供了4中国策略
         *      01:AbortPolicy:直接抛出异常,默认策略
         *      02:callerRunsPolicy:用调用者锁在的线程来执行任务
         *      03:DiscardOldestPolicy:丢弃阻塞队列中靠最前的任务,并执行当前的任务
         *      04:DiscardPolicy:直接丢弃任务
         *
         */

    }
}
